package cn.tedu.icop.basic.canal;
import cn.tedu.icop.basic.pojo.StationCanalPO;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.HashOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Component;

/**
 * 场站数据同步处理器
 * 数据库表  @CanalTable charging_station 要和 Redis 保持一致
 * charging_station 发生了变化  insert update delete
 *
 * charging_station 插入数据  通知 StationSyncHandler 调用 insert Redis插入数据
 * charging_station 更新数据  通知 StationSyncHandler 调用 update Redis更新数据
 * charging_station 删除数据  通知 StationSyncHandler 调用 delete Redis删除数据
 *
 *
 */
@Slf4j
@Component
//@CanalTable("charging_station")
public class StationSyncHandler /*implements EntryHandler<StationCanalPO> */{


   /* @Autowired
    private RedisTemplate redisTemplate;

    @Override
    public void insert(StationCanalPO stationCanalPO) {
        log.debug("数据表 charging_station 插入了新的数据:{}",stationCanalPO);
        EntryHandler.super.insert(stationCanalPO);
    }

    @Override
    public void update(StationCanalPO before, StationCanalPO after) {
        log.debug("数据表 charging_station 更新数据,更新之前:{}更新之后:{}",before,after);
        EntryHandler.super.update(before, after);
    }

    @Override
    public void delete(StationCanalPO stationCanalPO) {
        log.debug("数据表 charging_station 删除了数据:{}",stationCanalPO);
        //redisTemplate 删除对应的key
        EntryHandler.super.delete(stationCanalPO);
    }*/
}
